package com.lookup.api.handler.eventbus;

import com.lookup.api.handler.AbstractEventbusHandler;
import io.vertx.rxjava.core.MultiMap;
import io.vertx.rxjava.core.eventbus.Message;
import rx.Observable;


public class EchoEventbusHandler extends AbstractEventbusHandler<String> {

    @Override
    public Observable<String> handleInternal(MultiMap headers,
                                             Message<String> message) {
        return Observable.just("Echo message");
    }

}
